package com.piesat.quake.common.mqtt.entity;

import lombok.Getter;
import org.springframework.context.ApplicationEvent;

@Getter
public class MqttEvent extends ApplicationEvent {

    /**
     * 主题
     */
    private String topic;

    /**
     * 发送的消息
     */
    private byte[] message;

    public MqttEvent(Object source, String topic, byte[] message) {
        super(source);
        this.topic = topic;
        this.message = message;
    }
}
